5b781e04cf13b5f5e54fe9f48c9e7aff729782ad,modules/siddhi-extensions/input-mappers/map-input-mapper/src/test/java/org/wso2/siddhi/extension/input/mapper/map/MapInputMapperTestCase.java,MapInputMapperTestCase,subscriptionTest12,#,40

Before Change


    public void subscriptionTest12() throws InterruptedException {
        log.info("Subscription Test 12: Test an in memory transport with hashmap");

        Subscription subscription = Subscription.Subscribe(Transport.transport("inMemory"));
        subscription.map(Mapping.format("map"));
        subscription.insertInto("FooStream");

After Change


    public void subscriptionTest12() throws InterruptedException {
        log.info("Subscription Test 12: Test an in memory transport with default hashmap mapping");

        Subscription subscription = Subscription.Subscribe(Transport.transport("inMemory").option("topic","stock"));
        subscription.map(Mapping.format("map"));
        subscription.insertInto("FooStream");